#ifndef STREAM_H
#define STREAM_H

#include <zmq.hpp>
#include <string>

class Stream {
public:
    Stream(const std::string& address, const bool is_server);
    void sendMessage(const std::string& message, const std::string& identity);
    void receiveMessage();
private:
    zmq::context_t context;
    zmq::socket_t stream;
};

#endif // STREAM_H